package com.chinalanshen.mqtt.service;

import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;

public class GetMessage implements MessageHandler{
	
	public void handleMessage(Message<?> message) throws MessagingException {
		System.out.println("主题：" + message.getHeaders().get("mqtt_receivedTopic").toString());
		System.out.println("获取到的消息" + message.getPayload().toString());
	}

}
